package com.atguigu.sparkcore.day02

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

/**
 * Author atguigu
 * Date 2020/10/28 9:19
 */
object DoubleValueDemo {
    def main(args: Array[String]): Unit = {
        val conf: SparkConf = new SparkConf().setAppName("DoubleValueDemo").setMaster("local[2]")
        val sc: SparkContext = new SparkContext(conf)
        val list1 = List(30, 50, 70, 70, 60, 10, 20, 20, 20)
        val list2 = List(3, 50, 7, 60, 10, 20)
        val rdd1: RDD[Int] = sc.parallelize(list1, 2)
        val rdd2: RDD[Int] = sc.parallelize(list2, 3)
        
        // 交集
        //val rdd3 = rdd1.intersection(rdd2)
        //println(rdd3.getNumPartitions)
        
        // 并集  :: :::  +: ...
        //        val rdd3 = rdd1.union(rdd2)
        //        val rdd3 = rdd1 ++ rdd2
        
        // 差集
        val rdd3 = rdd1.subtract(rdd2)
        
        rdd3.collect.foreach(println)
        
        sc.stop()
        
    }
}

/*



 */